package org.idea.eaglemq.broker.rebalance.strategy;

import org.idea.eaglemq.broker.rebalance.ConsumerInstance;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;

/**
 * @author: LunBoWang
 * @description: 需要参与重平衡的消费组
 * @date: 2025/5/8 下午7:35
 * @version: 1.0
 */
public class ReBalanceInfo {

    private Map<String, List<ConsumerInstance>> consumeInstanceMap;
    //消费者发生变化的消费组
    private Map<String, Set<String>> changeConsumerGroupMap = new HashMap<>();

    public Map<String, List<ConsumerInstance>> getConsumeInstanceMap() {
        return consumeInstanceMap;
    }

    public void setConsumeInstanceMap(Map<String, List<ConsumerInstance>> consumeInstanceMap) {
        this.consumeInstanceMap = consumeInstanceMap;
    }

    public Map<String, Set<String>> getChangeConsumerGroupMap() {
        return changeConsumerGroupMap;
    }

    public void setChangeConsumerGroupMap(Map<String, Set<String>> changeConsumerGroupMap) {
        this.changeConsumerGroupMap = changeConsumerGroupMap;
    }
}
